package com.linkstec.mot.bean;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;

@Component("kafkaConfig")
public class KafkaConfig {

	@Value("#{kafkaSettings['kafka.auto.offset.reset']}")
	private String offsetReset;

	@Value("#{kafkaSettings['zookeeper.connect']}")
	private String zkList;

	@Value("#{kafkaSettings['kafka.group.id']}")
	private String groupId;

	@Value("#{kafkaSettings['kafka.enable.auto.commit']}")
	private String enableAutoCommit;

	@Value("#{kafkaSettings['kafka.auto.commit.interval.ms']}")
	private String commitInterval;

	@Value("#{kafkaSettings['kafka.fetch.message.max.bytes']}")
	private String messageMaxBytes;

	public String getOffsetReset() {
		return offsetReset;
	}

	public String getGroupId() {
		return groupId;
	}

	public String getCommitInterval() {
		return commitInterval;
	}

	public String getEnableAutoCommit() {
		return enableAutoCommit;
	}

	public String getZkList() {
		return zkList;
	}

	public String getMessageMaxBytes() {
		return messageMaxBytes;
	}

}
